package com.shanzhe.eshop.common.hdfs.nameNode.server;

/**
 * @Author yinwei
 * @create 2021/10/10
 * @Version 1.0
 * @desc nameNode的Rpc接口
 */
public class NameNodeRpcServer {

    /**
     * 负责管理元数据的核心组件
     */
    private FsNameSystem fsNameSystem;

    public NameNodeRpcServer(FsNameSystem fsNameSystem){
        this.fsNameSystem = fsNameSystem;
    }

    /**
     * 创建目录
     * @param path 目录路径
     * @return
     */
    public Boolean mkdir(String path){
        try {
            fsNameSystem.mkdir(path);
            return true;
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }

    /**
     * 启动Rpc server
     */
    public void start(){
        System.out.println("开始监听指定的Rps server的端口号，来接受请求");
    }

}
